package com.niit.utils

import org.apache.spark.SparkConf
import org.apache.spark.streaming.{Seconds, StreamingContext}

object SparkConnector {
  def getSparkConf(): StreamingContext = {
    val conf = new SparkConf().setMaster("local[*]").setAppName("sparkStreaming")
    val sc = new StreamingContext(conf, Seconds(2))
    sc.sparkContext.setLogLevel("error")
    sc
  }
}
